package com.yeeiee.convert;

import cn.hutool.db.Entity;
import org.apache.flink.table.api.Schema;

/**
 * converter
 */
public interface ClinkConverter {
    /**
     * 将源类型信息转换为flink sql类型
     */
    void convertToType(Entity entity, Schema.Builder builder);

    /**
     * 将flink sql类型转换为db类型
     */
    String convertToDb(Schema.UnresolvedColumn column);
}
